const fs = require("fs");
// 可读流
const rStream = fs.createReadStream("./text.txt");
  // 可写流
const wStream = fs.createWriteStream("./text1.txt");

// 这里是直接覆盖原来的文件， 之所以会覆盖，是因为每一处写入都会关闭，
rStream.pipe(wStream, {
  // 表示写入结束之后，自动关闭写入流, 默认是 true, 如果为 false，那么可写的 目标流一直打开, 会一直像目标文件写入内容
  end: false,
});

rStream.on("end", () => {
  wStream.end("fuck 结束了")
  console.log("end");
});


rStream.on("error", (err) => {
  console.log("error", err)
  rStream.close();
})

console.log(process.pid);

// setInterval(()=>{}, 5000)

// 查看 /proc/${pid}/fd 文件句柄的变化, 如果 可写流发生错误， 如果不关闭可写流，那么可读流的文件句柄会一直打开； 占用资源，造成内存泄露